var mysql=require("mysql");

data = {}
/*
config = {
    host: 'host',
    user: 'user',
    password: 'password',
    database: 'database',
    port: port
}
*/
pool = null;
data.init = function (config) {
    pool = mysql.createPool(config);
    return data;
}


data.query=function(sql,options,callback){
    pool.getConnection(function(err,conn){
        if(err){
            callback(err,null,null);
        }else{
            conn.query(sql,options,function(err,results,fields){
                //释放连接
                conn.release();
                if(err){
                    console.error("mysql error",err);
                      return;
                }
                //事件驱动回调
                callback(results,fields);
            });
        }
    });
};

module.exports=function (config) {
    return data.init(config);
};